package com.gomefinance.config;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

/**
 * @author zhangfuqiang3@gome.com.cn
 * @version 1.0
 * @date 2024/12/28
 * @description:
 **/
@Configuration
@ConfigurationProperties(prefix = "kafka.producer")
public class KafkaProducerProperties {
    /**
     * Bootstrap servers for Kafka.
     */
    private String bootstrapServers;

    /**
     * Key serializer class.
     */
    private String keySerializer = "org.apache.kafka.common.serialization.StringSerializer";

    /**
     * Value serializer class.
     */
    private String valueSerializer = "org.apache.kafka.common.serialization.StringSerializer";

    // Getters and Setters

    public String getBootstrapServers() {
        return bootstrapServers;
    }

    public void setBootstrapServers(String bootstrapServers) {
        this.bootstrapServers = bootstrapServers;
    }

    public String getKeySerializer() {
        return keySerializer;
    }

    public void setKeySerializer(String keySerializer) {
        this.keySerializer = keySerializer;
    }

    public String getValueSerializer() {
        return valueSerializer;
    }

    public void setValueSerializer(String valueSerializer) {
        this.valueSerializer = valueSerializer;
    }
}
